#Bonjour 服务发现

import { createServer, type Socket } from "node:net"

// Bonjour, crypto and console are globals; no import from "scripting".
const peers = new Set<Socket>()
const server = createServer(socket => {
  peers.add(socket)
  socket.on("close", () => peers.delete(socket))
  socket.on("error", console.error)
  socket.on("data", data => socket.write(typeof data === "string" ? data : new Uint8Array(data)))
})
server.on("error", console.error)
let publication: BonjourPublication | undefined
let browser: BonjourBrowser | undefined
let deadline: ReturnType<typeof setTimeout> | undefined
try {
  await new Promise<void>((resolve, reject) => {
    const fail = (error: Error) => reject(error)
    server.once("error", fail)
    server.listen(0, () => { server.removeListener("error", fail); resolve() })
  })
  const endpoint = server.address()
  if (!endpoint) throw new Error("Server is not listening")
  const name = "Scripting Demo " + crypto.randomUUID().slice(0, 8)
  publication = await Bonjour.publish({
    name, type: "_scripting._tcp", port: endpoint.port,
    txtRecord: { version: "1", binary: new Uint8Array([0, 255]) },
    includePeerToPeer: true,
  })
  const found = await new Promise<BonjourResolvedService>((resolve, reject) => {
    let resolving = false
    deadline = setTimeout(() => reject(new Error("Discovery timed out")), 10000)
    browser = Bonjour.browse({
      type: "_scripting._tcp", includePeerToPeer: true, onError: reject,
      onFound(service) {
        if (service.name !== name || resolving) return
        resolving = true
        void Bonjour.resolve(service, { timeout: 3000, includePeerToPeer: true }).then(resolve, reject)
      },
    })
  })
  console.log(found.name, found.hostname, found.port)
  console.log(new TextDecoder().decode(found.txtRecord.version)) // "1"
} finally {
  clearTimeout(deadline)
  browser?.stop()
  publication?.stop()
  for (const socket of peers) socket.destroy()
  if (server.listening) await new Promise<void>(resolve => server.close(() => resolve()))
}